package com.example.artemis.config;

/**
 * 生产者配置实现类
 * 基于原有代码的生产者配置参数
 */
public class QueueProducerConfig extends AbstractProducerConfig {

    /**
     * 生产者数量 - 3个生产者
     */
    @Override
    public int getProducerCount() {
        return 3;
    }

    /**
     * 每个生产者发送的消息数量 - 20条消息
     */
    @Override
    public int getMessagesPerProducer() {
        return 20;
    }

    /**
     * 队列数量 - 5个分片队列
     */
    @Override
    public int getQueueCount() {
        return 5;
    }

    /**
     * 消息发送间隔 - 100毫秒间隔
     */
    @Override
    public long getMessageIntervalMs() {
        return 100L;
    }
}